package com.gjy.design.observer.disruptor;

/**
 * @author gjy
 * @version 1.0
 * @since 2025-11-08 09:14:11
 */
public class MessageEvent extends Event {

    private final Object message;
    private final String messageId;

    public MessageEvent(String topic, Object message, String messageId) {
        super(topic);
        this.message = message;
        this.messageId = messageId;
    }

    public Object getMessage() {
        return message;
    }

    public String getMessageId() {
        return messageId;
    }

}
